package cn.xiaopengstack.domain.task.repository;

import cn.xiaopengstack.domain.task.model.TaskEntity;

import java.util.List;

/**
 * @author jiangyangang
 */
public interface ITaskRepository {

    /**
     * 查询发送失败的task记录
     * @param db
     * @return
     */
    List<TaskEntity> queryFailedTask(Integer db);

    /**
     * 发送task消息
     * @param taskEntity
     */
    void sendTaskMq(TaskEntity taskEntity);

    /**
     * 发送消息失败
     * @param taskEntity
     */
    void updateTaskSendMessageFail(TaskEntity taskEntity);

    /**
     * 发送消息成功
     * @param taskEntity
     */
    void updateTaskSendMessageCompleted(TaskEntity taskEntity);
}
